package com.repeat.member.mq.consump;

import com.repeat.member.config.FanoutConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class FanoutConsump {
    @RabbitListener(queues = FanoutConfig.FANOUT_QUEUE1)
    public void fanoutQueue1(String consump) {
         System.out.println("第一个广播消息:"+consump);
    }
    @RabbitListener(queues = FanoutConfig.FANOUT_QUEUE2)
    public void fanoutQueue2(String consump) {
        System.out.println("第二个广播消息:"+consump);
    }
    @RabbitListener(queues = FanoutConfig.FANOUT_QUEUE3)
    public void fanoutQueue3(String consump) {
        System.out.println("第三个广播消息:"+consump);
    }
}
